category: sub_main
step: 2_staging
sub_step: 1_join
in_main_macro: join
doc_status: readymacro join_yd_datestat_smart
| Name | Category | In Sub-Main Macro | Doc Status |
|---|---|---|---|
| get_min_max_date | auxiliary | join_mt_datestat, join_yd_datestat, join_yd_datestat_smart, join_ym_events | ready |
| get_relations_by_re | auxiliary | join_appmetrica_events, join_appmetrica_registry_appprofilematching, join_appsflyer_events, join_mt_datestat, join_sheets_periodstat, join_vkads_datestat, join_utmcraft_registry_utmhashregistry, join_yd_datestat, join_yd_datestat_smart, join_ym_events | ready |
Этот подвид макроса join предназначен для работы с данными источника yd (они относятся к пайплайну datestat) - отдельная версия именно для данных, где есть smart.
Этот макрос принимает следующие аргументы:
sourcetype_name,
pipeline_name,
relations_dict,
date_from,
date_to,
params,
limit0=none
Макрос обрабатывает данные источника yd, для которого есть стримы и custom_report, иcustom_report_smart. Эти данные относятся к пайплайну datestat.
Для этих данных макрос ищет relations при помощи вспомогательного макроса get_relations_by_re, затем создаёт таблицу-источник при помощи вспомогательного макроса dbt_utils.union_relations. (Этот макрос из пакета dbt_utils, он не относится к datacraft).
При помощи дополнительного макроса get_min_max_date в макросе задаются переменные
date_from и date_to, которые участвуют в отборе данных.
Далее полученные данные макрос обрабатывает (происходит переименование полей, для некоторых столбцов вводится LowCardinality).
Для этой таблицы задаётся её линк (это будет использоваться на будущих шагах):
toLowCardinality('AdCostStat') AS __linkЕсли аргумент limit0 активирован, то в конце SQL-запроса будет добавлено LIMIT 0.